

# 创建topic
kafka-topics --create --zookeeper cdh01:2181/kafka --replication-factor 1 --partitions 1 --topic cars

#去启动flume
flume-ng agent -n agent -f ./car_file_to_kafka.conf -Dflume.root.logger=DEBUG,console

# 启动flink任务
sql-client.sh -f real_card_flow.sql